package com.fjec.compensate.service;

import com.fjec.compensate.entity.BizMqCompensate;
import com.baomidou.mybatisplus.extension.service.IService;
import org.springframework.amqp.core.Message;

/**
 * <p>
 * 019.消息队列补偿表 服务类
 * </p>
 *
 * @author admin
 * @since 2020-10-19
 */
public interface IBizMqCompensateService extends IService<BizMqCompensate> {

    /**
     * 处理延时补偿消息
     *
     * @param message
     * @throws Exception
     */
    boolean handleDelayMessage(Long dataId, Integer msgType, Message message);

    /**
     * 处理消费成功消息
     *
     * @param message
     * @throws Exception
     */
    boolean handleCompleteMessage(Long dataId, Integer msgType, Message message);
}
